package com.sl.plugin.step.json;


import com.sl.core.engine.meta.impl.AbstractProcessCompDescriptor;
import com.sl.core.engine.step.ProcessCompService;
import com.sl.core.engine.step.impl.AbstractProcessComp;

import java.util.List;
import java.util.Map;

/**
 *
 */
public class JsonJoinByComp extends AbstractProcessComp<List<Map<String, Object>>, List<Map<String, Object>>> implements ProcessCompService {


    public JsonJoinByComp(AbstractProcessCompDescriptor abstractProcessCompDescriptor) {
        super(abstractProcessCompDescriptor);
    }

    @Override
    public List<Map<String, Object>> input(List<Map<String, Object>> param) {
        //要join首先要满足至少两个元素,加入A/B

        //B元素要groupBy
        //A元素要循环然后根据BgroupBy的map去根据AB两个的映射关系进行join
        //最后塞到A的元素里
        return null;

    }

}
